Micron Document
🎖️GitЯра🎖️

Node / meshtastic / Meshtastic-Android / files / core / database / src / commonTest / kotlin / org / meshtastic / core / database / dao / CommonNodeIdentityMigrationDaoTest.kt

Displaying Raw • Download

core/database/src/commonTest/kotlin/org/meshtastic/core/database/dao/CommonNodeIdentityMigrationDaoTest.kt d5848ad5e02bd9b5b1726bedfa51ceb0faaa0240 (d5848ad5) Text, 11.94 KB

T8b949e/*
* Copyright (c) 2026 Meshtastic LLC
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
Tff7b72package T7ee787org.meshtastic.core.database.dao

Tff7b72import T7ee787kotlinx.coroutines.test.runTest
Tff7b72import T7ee787okio.ByteString
Tff7b72import T7ee787okio.ByteString.Companion.toByteString
Tff7b72import T7ee787org.meshtastic.core.common.util.crc32
Tff7b72import T7ee787org.meshtastic.core.database.MeshtasticDatabase
Tff7b72import T7ee787org.meshtastic.core.database.entity.MyNodeEntity
Tff7b72import T7ee787org.meshtastic.core.database.entity.NodeEntity
Tff7b72import T7ee787org.meshtastic.core.database.entity.Packet
Tff7b72import T7ee787org.meshtastic.core.database.entity.ReactionEntity
Tff7b72import T7ee787org.meshtastic.core.database.getInMemoryDatabaseBuilder
Tff7b72import T7ee787org.meshtastic.core.model.DataPacket
Tff7b72import T7ee787org.meshtastic.core.model.NodeAddress
Tff7b72import T7ee787org.meshtastic.proto.HardwareModel
Tff7b72import T7ee787org.meshtastic.proto.PortNum
Tff7b72import T7ee787org.meshtastic.proto.User
Tff7b72import T7ee787kotlin.test.AfterTest
Tff7b72import T7ee787kotlin.test.Test
Tff7b72import T7ee787kotlin.test.assertEquals
Tff7b72import T7ee787kotlin.test.assertNotNull
Tff7b72import T7ee787kotlin.test.assertNull
Tff7b72import T7ee787kotlin.test.assertTrue

T8b949e/**
* Covers the device-identity reconciliation in [NodeInfoDao.installConfig]: firmware 2.8 renumbers every device
* (`my_node_num = crc32(public_key)`), and erases/manual re-keys renumber again — the stale identity must be migrated
* (or vetoed for provably different hardware) instead of shadowing the new one.
*
* Abstract, per repo convention: the androidHostTest subclass supplies the Robolectric runner (Room's android target
* needs real `android.database` exception classes for its upsert fallback), and a jvmTest subclass runs it on the JVM
* target.
*/
Tff7b72abstract Tff7b72class T56d364CommonNodeIdentityMigrationDaoTest Tb4b4b4{

Tff7b72private Tff7b72lateinit Tff7b72var Te6edf3databaseTb4b4b4: Te6edf3MeshtasticDatabase
Tff7b72private Tff7b72lateinit Tff7b72var Te6edf3daoTb4b4b4: Te6edf3NodeInfoDao
Tff7b72private Tff7b72lateinit Tff7b72var Te6edf3packetDaoTb4b4b4: Te6edf3PacketDao

T8b949e// Ingestion hex-encodes device_id, and validDeviceIdOrNull requires that shape.
Tff7b72private Tff7b72val Te6edf3deviceIdA Tff7b72= Ta5d6ff"Ta5d6ffa1b2c3d4e5f60718a9b0c1d2e3f40516Ta5d6ff"
Tff7b72private Tff7b72val Te6edf3deviceIdB Tff7b72= Ta5d6ff"Ta5d6ffffeeddccbbaa99887766554433221100Ta5d6ff"

Tff7b72private Tff7b72val Te6edf3keyA Tff7b72= Te6edf3ByteArrayTb4b4b4(T79c0ff3T79c0ff2Tb4b4b4) Tb4b4b4{ T79c0ff1 Tb4b4b4}Tb4b4b4.Te6edf3toByteStringTb4b4b4(Tb4b4b4)
Tff7b72private Tff7b72val Te6edf3keyB Tff7b72= Te6edf3ByteArrayTb4b4b4(T79c0ff3T79c0ff2Tb4b4b4) Tb4b4b4{ T79c0ff2 Tb4b4b4}Tb4b4b4.Te6edf3toByteStringTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3oldNum Tff7b72= T79c0ff1T79c0ff0T79c0ff0
Tff7b72private Tff7b72val Te6edf3oldId Tff7b72= Te6edf3NodeAddressTb4b4b4.Te6edf3numToDefaultIdTb4b4b4(Te6edf3oldNumTb4b4b4)

Tff7b72private Tff7b72fun Td2a8ffmyNodeEntityTb4b4b4(Te6edf3numTb4b4b4: Tffa657IntTb4b4b4, Te6edf3deviceIdTb4b4b4: Tffa657String? Tff7b72= Te6edf3MyNodeEntityTb4b4b4.Te6edf3DEVICE_ID_UNKNOWNTb4b4b4) Tff7b72= Te6edf3MyNodeEntityTb4b4b4(
Te6edf3myNodeNum Tff7b72= Te6edf3numTb4b4b4,
Te6edf3model Tff7b72= Ta5d6ff"Ta5d6ffTBEAMTa5d6ff"Tb4b4b4,
Te6edf3firmwareVersion Tff7b72= Ta5d6ff"Ta5d6ff2.8.0Ta5d6ff"Tb4b4b4,
Te6edf3couldUpdate Tff7b72= Tff7b72falseTb4b4b4,
Te6edf3shouldUpdate Tff7b72= Tff7b72falseTb4b4b4,
Te6edf3currentPacketId Tff7b72= T79c0ff1LTb4b4b4,
Te6edf3messageTimeoutMsec Tff7b72= T79c0ff3T79c0ff0T79c0ff0T79c0ff0T79c0ff0T79c0ff0Tb4b4b4,
Te6edf3minAppVersion Tff7b72= T79c0ff1Tb4b4b4,
Te6edf3maxChannels Tff7b72= T79c0ff8Tb4b4b4,
Te6edf3hasWifi Tff7b72= Tff7b72falseTb4b4b4,
Te6edf3deviceId Tff7b72= Te6edf3deviceIdTb4b4b4,
Tb4b4b4)

Tff7b72private Tff7b72fun Td2a8ffnodeEntityTb4b4b4(
Te6edf3numTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3keyTb4b4b4: Te6edf3ByteStringTb4b4b4,
Te6edf3longNameTb4b4b4: Tffa657String Tff7b72= Ta5d6ff"Ta5d6ffNode Tffd700$Te6edf3numTa5d6ff"Tb4b4b4,
Te6edf3notesTb4b4b4: Tffa657String Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4,
Te6edf3isFavoriteTb4b4b4: Tffa657Boolean Tff7b72= Tff7b72falseTb4b4b4,
Tb4b4b4) Tff7b72= Te6edf3NodeEntityTb4b4b4(
Te6edf3num Tff7b72= Te6edf3numTb4b4b4,
Te6edf3user Tff7b72=
Te6edf3UserTb4b4b4(
Te6edf3id Tff7b72= Te6edf3NodeAddressTb4b4b4.Te6edf3numToDefaultIdTb4b4b4(Te6edf3numTb4b4b4)Tb4b4b4,
Te6edf3long_name Tff7b72= Te6edf3longNameTb4b4b4,
Te6edf3short_name Tff7b72= Te6edf3longNameTb4b4b4.Te6edf3takeLastTb4b4b4(T79c0ff4Tb4b4b4)Tb4b4b4,
Te6edf3hw_model Tff7b72= Te6edf3HardwareModelTb4b4b4.Te6edf3TBEAMTb4b4b4,
Te6edf3public_key Tff7b72= Te6edf3keyTb4b4b4,
Tb4b4b4)Tb4b4b4,
Te6edf3notes Tff7b72= Te6edf3notesTb4b4b4,
Te6edf3isFavorite Tff7b72= Te6edf3isFavoriteTb4b4b4,
Te6edf3lastHeard Tff7b72= T79c0ff1T79c0ff0T79c0ff0T79c0ff0Tb4b4b4,
Tb4b4b4)

Tff7b72private Tff7b72fun Td2a8ffpacketTb4b4b4(Te6edf3ownerTb4b4b4: Tffa657IntTb4b4b4, Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4) Tff7b72= Te6edf3PacketTb4b4b4(
Te6edf3uuid Tff7b72= T79c0ff0LTb4b4b4,
Te6edf3myNodeNum Tff7b72= Te6edf3ownerTb4b4b4,
Te6edf3port_num Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4.Te6edf3valueTb4b4b4,
Te6edf3contact_key Tff7b72= Te6edf3contactKeyTb4b4b4,
Te6edf3received_time Tff7b72= T79c0ff1T79c0ff0T79c0ff0T79c0ff0LTb4b4b4,
Te6edf3read Tff7b72= Tff7b72trueTb4b4b4,
Te6edf3data Tff7b72=
Te6edf3DataPacketTb4b4b4(
Te6edf3to Tff7b72= Te6edf3NodeAddressTb4b4b4.Te6edf3ID_BROADCASTTb4b4b4,
Te6edf3bytes Tff7b72= Ta5d6ff"Ta5d6ffhelloTa5d6ff"Tb4b4b4.Te6edf3encodeToByteArrayTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3toByteStringTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3dataType Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3TEXT_MESSAGE_APPTb4b4b4.Te6edf3valueTb4b4b4,
Tb4b4b4)Tb4b4b4,
Tb4b4b4)

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffcreateDbTb4b4b4(Te6edf3myNodeTb4b4b4: Te6edf3MyNodeEntityTb4b4b4) Tb4b4b4{
Te6edf3database Tff7b72= Te6edf3getInMemoryDatabaseBuilderTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3buildTb4b4b4(Tb4b4b4)
Te6edf3dao Tff7b72= Te6edf3databaseTb4b4b4.Te6edf3nodeInfoDaoTb4b4b4(Tb4b4b4)
Te6edf3packetDao Tff7b72= Te6edf3databaseTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)
Te6edf3daoTb4b4b4.Te6edf3setMyNodeInfoTb4b4b4(Te6edf3myNodeTb4b4b4)
Tb4b4b4}

Tf0883e@AfterTest
Tff7b72fun Td2a8ffcloseDbTb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3databaseTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ffrenumberMigratesHistoryAndLocalStateTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Te6edf3createDbTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4)
Te6edf3daoTb4b4b4.Te6edf3upsertTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3keyATb4b4b4, Te6edf3notes Tff7b72= Ta5d6ff"Ta5d6ffmy notesTa5d6ff"Tb4b4b4, Te6edf3isFavorite Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4)
Te6edf3packetDaoTb4b4b4.Te6edf3insertTb4b4b4(Te6edf3packetTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3contactKey Tff7b72= Ta5d6ff"Ta5d6ff0Tffd700$Te6edf3oldIdTa5d6ff"Tb4b4b4)Tb4b4b4) T8b949e// note-to-self thread
Te6edf3packetDaoTb4b4b4.Te6edf3insertTb4b4b4(Te6edf3packetTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3contactKey Tff7b72= Ta5d6ff"Ta5d6ff1!deadbeefTa5d6ff"Tb4b4b4)Tb4b4b4) T8b949e// DM with a peer
Te6edf3packetDaoTb4b4b4.Te6edf3insertTb4b4b4(
Te6edf3ReactionEntityTb4b4b4(Te6edf3myNodeNum Tff7b72= Te6edf3oldNumTb4b4b4, Te6edf3replyId Tff7b72= T79c0ff7Tb4b4b4, Te6edf3userId Tff7b72= Ta5d6ff"Ta5d6ff!deadbeefTa5d6ff"Tb4b4b4, Te6edf3emoji Tff7b72= Ta5d6ff"Ta5d6ffxTa5d6ff"Tb4b4b4, Te6edf3timestamp Tff7b72= T79c0ff1LTb4b4b4)Tb4b4b4,
Tb4b4b4)

Tff7b72val Te6edf3newNum Tff7b72= T79c0ff2T79c0ff0T79c0ff0
Tff7b72val Te6edf3newId Tff7b72= Te6edf3NodeAddressTb4b4b4.Te6edf3numToDefaultIdTb4b4b4(Te6edf3newNumTb4b4b4)
T8b949e// Key changed too (manual regen / erase): continuity must not depend on the key.
Tff7b72val Te6edf3removed Tff7b72= Te6edf3daoTb4b4b4.Te6edf3installConfigTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3newNumTb4b4b4)Tb4b4b4, Te6edf3listOfTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3newNumTb4b4b4, Te6edf3keyBTb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3listOfTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4, Te6edf3removedTb4b4b4)
Te6edf3assertEqualsTb4b4b4(Te6edf3newNumTb4b4b4, Te6edf3daoTb4b4b4.Te6edf3getMyNodeEntityTb4b4b4(Tb4b4b4)Tff7b72?.Te6edf3myNodeNumTb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4, Ta5d6ff"Ta5d6ffstale self row must be droppedTa5d6ff"Tb4b4b4)

Tff7b72val Te6edf3newSelf Tff7b72= Te6edf3assertNotNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3newNumTb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3node
Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffmy notesTa5d6ff"Tb4b4b4, Te6edf3newSelfTb4b4b4.Te6edf3notesTb4b4b4, Ta5d6ff"Ta5d6ffapp-local notes must follow the deviceTa5d6ff"Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3newSelfTb4b4b4.Te6edf3isFavoriteTb4b4b4, Ta5d6ff"Ta5d6fffavorite flag must follow the deviceTa5d6ff"Tb4b4b4)

Tff7b72val Te6edf3packets Tff7b72= Te6edf3packetDaoTb4b4b4.Te6edf3getAllPacketsSnapshotTb4b4b4(Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3packetsTb4b4b4.Te6edf3isNotEmptyTb4b4b4(Tb4b4b4)Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3packetsTb4b4b4.Te6edf3all Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3myNodeNum Tff7b72=Tff7b72= Te6edf3newNum Tb4b4b4}Tb4b4b4, Ta5d6ff"Ta5d6ffmessage history must be re-scoped to the new numTa5d6ff"Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3packetsTb4b4b4.Te6edf3any Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3contact_key Tff7b72=Tff7b72= Ta5d6ff"Ta5d6ff0Tffd700$Te6edf3newIdTa5d6ff" Tb4b4b4}Tb4b4b4, Ta5d6ff"Ta5d6ffnote-to-self thread must follow the new idTa5d6ff"Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3packetsTb4b4b4.Te6edf3any Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3contact_key Tff7b72=Tff7b72= Ta5d6ff"Ta5d6ff1!deadbeefTa5d6ff" Tb4b4b4}Tb4b4b4, Ta5d6ff"Ta5d6ffpeer DM threads must be untouchedTa5d6ff"Tb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3packetDaoTb4b4b4.Te6edf3getAllReactionsSnapshotTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3all Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3myNodeNum Tff7b72=Tff7b72= Te6edf3newNum Tb4b4b4}Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ffrenumberDropsStaleSelfListedInSameBatchTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Te6edf3createDbTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4)
Te6edf3daoTb4b4b4.Te6edf3upsertTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3keyATb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3newNum Tff7b72= T79c0ff2T79c0ff0T79c0ff0
T8b949e// A device mid-transition can still stream its old identity alongside the new one.
Tff7b72val Te6edf3removed Tff7b72=
Te6edf3daoTb4b4b4.Te6edf3installConfigTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3newNumTb4b4b4)Tb4b4b4, Te6edf3listOfTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3keyATb4b4b4)Tb4b4b4, Te6edf3nodeEntityTb4b4b4(Te6edf3newNumTb4b4b4, Te6edf3keyATb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3listOfTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4, Te6edf3removedTb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4, Ta5d6ff"Ta5d6ffold identity in the same batch must not be resurrectedTa5d6ff"Tb4b4b4)
Te6edf3assertNotNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3newNumTb4b4b4)Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ffsameHardwareEraseMigratesAcrossKeyChangeTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Te6edf3createDbTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3deviceId Tff7b72= Te6edf3deviceIdATb4b4b4)Tb4b4b4)
Te6edf3daoTb4b4b4.Te6edf3upsertTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3keyATb4b4b4, Te6edf3notes Tff7b72= Ta5d6ff"Ta5d6ffkeep meTa5d6ff"Tb4b4b4)Tb4b4b4)
Te6edf3packetDaoTb4b4b4.Te6edf3insertTb4b4b4(Te6edf3packetTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3contactKey Tff7b72= Ta5d6ff"Ta5d6ff1!deadbeefTa5d6ff"Tb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3newNum Tff7b72= T79c0ff3T79c0ff0T79c0ff0
Tff7b72val Te6edf3removed Tff7b72= Te6edf3daoTb4b4b4.Te6edf3installConfigTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3newNumTb4b4b4, Te6edf3deviceId Tff7b72= Te6edf3deviceIdATb4b4b4)Tb4b4b4, Te6edf3listOfTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3newNumTb4b4b4, Te6edf3keyBTb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3listOfTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4, Te6edf3removedTb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffkeep meTa5d6ff"Tb4b4b4, Te6edf3assertNotNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3newNumTb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3nodeTb4b4b4.Te6edf3notesTb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3packetDaoTb4b4b4.Te6edf3getAllPacketsSnapshotTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3all Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3myNodeNum Tff7b72=Tff7b72= Te6edf3newNum Tb4b4b4}Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ffdifferentHardwareVetoesHistoryMigrationTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Te6edf3createDbTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3deviceId Tff7b72= Te6edf3deviceIdATb4b4b4)Tb4b4b4)
Te6edf3daoTb4b4b4.Te6edf3upsertTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3keyATb4b4b4, Te6edf3notes Tff7b72= Ta5d6ff"Ta5d6ffold deviceTa5d6ff"Tb4b4b4)Tb4b4b4)
Te6edf3packetDaoTb4b4b4.Te6edf3insertTb4b4b4(Te6edf3packetTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3contactKey Tff7b72= Ta5d6ff"Ta5d6ff1!deadbeefTa5d6ff"Tb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3newNum Tff7b72= T79c0ff3T79c0ff0T79c0ff0
Tff7b72val Te6edf3removed Tff7b72= Te6edf3daoTb4b4b4.Te6edf3installConfigTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3newNumTb4b4b4, Te6edf3deviceId Tff7b72= Te6edf3deviceIdBTb4b4b4)Tb4b4b4, Te6edf3listOfTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3newNumTb4b4b4, Te6edf3keyBTb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3listOfTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4, Te6edf3removedTb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4, Ta5d6ff"Ta5d6ffstale self row is dropped even when history is not migratedTa5d6ff"Tb4b4b4)
Tff7b72val Te6edf3newSelf Tff7b72= Te6edf3assertNotNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3newNumTb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3node
Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3newSelfTb4b4b4.Te6edf3notesTb4b4b4, Ta5d6ff"Ta5d6ffdifferent hardware must not inherit app-local stateTa5d6ff"Tb4b4b4)
Te6edf3assertTrueTb4b4b4(
Te6edf3packetDaoTb4b4b4.Te6edf3getAllPacketsSnapshotTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3all Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3myNodeNum Tff7b72=Tff7b72= Te6edf3oldNum Tb4b4b4}Tb4b4b4,
Ta5d6ff"Ta5d6ffhistory of different hardware stays scoped under the old numTa5d6ff"Tb4b4b4,
Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ffsameNumInstallLeavesEverythingInPlaceTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Te6edf3createDbTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4)
Te6edf3daoTb4b4b4.Te6edf3upsertTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3keyATb4b4b4, Te6edf3notes Tff7b72= Ta5d6ff"Ta5d6ffsteadyTa5d6ff"Tb4b4b4)Tb4b4b4)
Te6edf3packetDaoTb4b4b4.Te6edf3insertTb4b4b4(Te6edf3packetTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3contactKey Tff7b72= Ta5d6ff"Ta5d6ff1!deadbeefTa5d6ff"Tb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3removed Tff7b72= Te6edf3daoTb4b4b4.Te6edf3installConfigTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4, Te6edf3listOfTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3keyATb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3emptyListTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3removedTb4b4b4)
Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffsteadyTa5d6ff"Tb4b4b4, Te6edf3assertNotNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3nodeTb4b4b4.Te6edf3notesTb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3packetDaoTb4b4b4.Te6edf3getAllPacketsSnapshotTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3all Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3myNodeNum Tff7b72=Tff7b72= Te6edf3oldNum Tb4b4b4}Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ffinstallTrustsDeviceReportedKeyChangeForSelfTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Te6edf3createDbTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4)
Te6edf3daoTb4b4b4.Te6edf3upsertTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3keyATb4b4b4)Tb4b4b4)

T8b949e// Same num, new key (2.7-line erase keeps the MAC-derived num). Without the install-time
T8b949e// trust this would poison the local node's key to ERROR_BYTE_STRING and break PKI traffic.
Te6edf3daoTb4b4b4.Te6edf3installConfigTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4, Te6edf3listOfTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3keyBTb4b4b4)Tb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3self Tff7b72= Te6edf3assertNotNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3node
Te6edf3assertEqualsTb4b4b4(Te6edf3keyBTb4b4b4, Te6edf3selfTb4b4b4.Te6edf3publicKeyTb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ffcanonicalNeighborRenumberMigratesInInstallBatchTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Te6edf3createDbTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4)
Tff7b72val Te6edf3peerOldNum Tff7b72= T79c0ff5T79c0ff0T79c0ff0
Tff7b72val Te6edf3peerOldId Tff7b72= Te6edf3NodeAddressTb4b4b4.Te6edf3numToDefaultIdTb4b4b4(Te6edf3peerOldNumTb4b4b4)
Te6edf3daoTb4b4b4.Te6edf3upsertTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3peerOldNumTb4b4b4, Te6edf3keyBTb4b4b4, Te6edf3notes Tff7b72= Ta5d6ff"Ta5d6ffpeer noteTa5d6ff"Tb4b4b4, Te6edf3isFavorite Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4)
Te6edf3packetDaoTb4b4b4.Te6edf3insertTb4b4b4(Te6edf3packetTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3contactKey Tff7b72= Ta5d6ff"Ta5d6ff0Tffd700$Te6edf3peerOldIdTa5d6ff"Tb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3peerNewNum Tff7b72= Te6edf3keyBTb4b4b4.Te6edf3crc32Tb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4) T8b949e// the firmware 2.8 canonical num for this key
Tff7b72val Te6edf3peerNewId Tff7b72= Te6edf3NodeAddressTb4b4b4.Te6edf3numToDefaultIdTb4b4b4(Te6edf3peerNewNumTb4b4b4)
Te6edf3daoTb4b4b4.Te6edf3installConfigTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4, Te6edf3listOfTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4, Te6edf3keyATb4b4b4)Tb4b4b4, Te6edf3nodeEntityTb4b4b4(Te6edf3peerNewNumTb4b4b4, Te6edf3keyBTb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3assertNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3peerOldNumTb4b4b4)Tb4b4b4, Ta5d6ff"Ta5d6ffpeer's pre-2.8 row must be migrated awayTa5d6ff"Tb4b4b4)
Tff7b72val Te6edf3migrated Tff7b72= Te6edf3assertNotNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3peerNewNumTb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3node
Te6edf3assertEqualsTb4b4b4(Ta5d6ff"Ta5d6ffpeer noteTa5d6ff"Tb4b4b4, Te6edf3migratedTb4b4b4.Te6edf3notesTb4b4b4)
Te6edf3assertTrueTb4b4b4(Te6edf3migratedTb4b4b4.Te6edf3isFavoriteTb4b4b4)
Te6edf3assertTrueTb4b4b4(
Te6edf3packetDaoTb4b4b4.Te6edf3getAllPacketsSnapshotTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3any Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3contact_key Tff7b72=Tff7b72= Ta5d6ff"Ta5d6ff0Tffd700$Te6edf3peerNewIdTa5d6ff" Tb4b4b4}Tb4b4b4,
Ta5d6ff"Ta5d6ffthe DM thread must follow the peer's new idTa5d6ff"Tb4b4b4,
Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ffnonCanonicalKeyConflictKeepsExistingIdentityTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Te6edf3createDbTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4)
Tff7b72val Te6edf3peerNum Tff7b72= T79c0ff5T79c0ff0T79c0ff0
Te6edf3daoTb4b4b4.Te6edf3upsertTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3peerNumTb4b4b4, Te6edf3keyBTb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3impostorNum Tff7b72= T79c0ff6T79c0ff0T79c0ff0 T8b949e// not crc32(keyB): an arbitrary num claiming a known key
Te6edf3daoTb4b4b4.Te6edf3installConfigTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4, Te6edf3listOfTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3impostorNumTb4b4b4, Te6edf3keyBTb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3assertNotNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3peerNumTb4b4b4)Tb4b4b4, Ta5d6ff"Ta5d6ffexisting identity must be kept on a non-canonical conflictTa5d6ff"Tb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3impostorNumTb4b4b4)Tb4b4b4, Ta5d6ff"Ta5d6ffnon-canonical claimant must not be insertedTa5d6ff"Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ffsingleUpsertNeverMigratesEvenForCanonicalNumTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{
Te6edf3createDbTb4b4b4(Te6edf3myNodeEntityTb4b4b4(Te6edf3oldNumTb4b4b4)Tb4b4b4)
Tff7b72val Te6edf3peerOldNum Tff7b72= T79c0ff5T79c0ff0T79c0ff0
Te6edf3daoTb4b4b4.Te6edf3upsertTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3peerOldNumTb4b4b4, Te6edf3keyBTb4b4b4, Te6edf3isFavorite Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4)

T8b949e// Mesh-time upserts are unauthenticated: even a canonical crc32(key) num must not migrate
T8b949e// identity — that only happens through installConfig (trusted local link).
Tff7b72val Te6edf3peerNewNum Tff7b72= Te6edf3keyBTb4b4b4.Te6edf3crc32Tb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)
Te6edf3daoTb4b4b4.Te6edf3upsertTb4b4b4(Te6edf3nodeEntityTb4b4b4(Te6edf3peerNewNumTb4b4b4, Te6edf3keyBTb4b4b4)Tb4b4b4)

Te6edf3assertNotNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3peerOldNumTb4b4b4)Tb4b4b4, Ta5d6ff"Ta5d6ffexisting identity must be kept on mesh-time conflictsTa5d6ff"Tb4b4b4)
Te6edf3assertNullTb4b4b4(Te6edf3daoTb4b4b4.Te6edf3getNodeByNumTb4b4b4(Te6edf3peerNewNumTb4b4b4)Tb4b4b4, Ta5d6ff"Ta5d6ffmesh-time claimant must not be insertedTa5d6ff"Tb4b4b4)
Tb4b4b4}
Tb4b4b4}

Served by rngit 1.5.0 - Generated in 0.11s